package com.study.config;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;

//import javax.annotation.PostConstruct;

/* by yours.tools - online tools website : yours.tools/zh/formatcss.html */
//@Configuration
@Slf4j
public class RabbitMQConfig {
//    @Autowired
//    RabbitTemplate rabbitTemplate;
//
//    @PostConstruct //创建RabbitMQConfig对象后，执行这个方法
//    public void initRabbitTemplate() {
//        //设置确认回调
//        rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
//            /**
//             * @param correlationData 当前消息的唯一关联数据（这个消息的唯一id）
//             * @param ack 消息是否成功收到
//             * @param cause  失败的原因
//             */
//            @Override
//            public void confirm(CorrelationData correlationData, boolean ack, String cause) {
//                log.info("confirm=>correlationData【{}】=>ack【{}】=>cause【{}】 ", correlationData, ack, cause);
//            }
//        });
//    }
}